package org.gas.barapraja.proc.buffer;

import org.gas.barapraja.db.entity.Message;
import org.gas.barapraja.proc.PduProcessor;

public abstract class GasQueuePool {
	
	private static GasQueue<Message> messageQueue;
	
	private static GasQueue<PduProcessor> processorQueue;
	
	public static GasQueue<Message> messageQueueInstance(){
		if(messageQueue==null){
			messageQueue=new MessageBufferQueue();
		}
		return messageQueue;
	}
	
	public static GasQueue<PduProcessor> pduProcessorQueue(){
		return processorQueue;
	}

}
